self.state = "disconnected"
self.transport = None
- def getDestination(self):
- raise NotImplementedError()
-
def connectTransport(self):
raise NotImplementedError()
raise IOError("unknown service: " + ex)
return port
- def getDestination(self):
- return (self.host, self.port)
-
def connectTransport(self):
self.transport = TCPClientConnection(
self.host, self.port, self.bindAddress, self)
l.startListening()
return l
-def SetCloExec(SocketListener):
- SocketListener.setCloExec()
-
def connectTCP(host, port, factory, timeout=None, bindAddress=None):
c = TCPConnector(host, port, factory, timeout=timeout, bindAddress=bindAddress)
c.connect()
self.addr = path
self.timeout = timeout
- def getDestination(self):
- return self.addr
-
def connectTransport(self):
self.transport = UnixClientConnection(self.addr, self)
self.transport.connect(self.timeout)